package org.atlantis.datasink.utils;

import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class SimpleExecutor implements Executor {

	private ExecutorService executor = Executors.newCachedThreadPool();

	@Override
	public void execute(Runnable command) {
		executor.execute(command);
	}

	public void destory() {
		executor.shutdownNow();
	}
}
